/**
 * BrandBigData.com Inc.
 * Copyright (c) 2016 All Rights Reserved.
 */
package com.qibao.toolkit.queue;

/**
 * @author xumin
 * @version $Id:QueueConsumer.java, v0.1 2017/12/19 18:26 xumin
 */
public interface QueueConsumer {

    /**
     * 消费队列里面的消息，默认线程数为1
     *
     * @param topic          要消费的topic
     * @param messageHandler 消息的处理逻辑
     */
    void consume(String topic, MessageHandler messageHandler);

    /**
     * @param threadNum      消费的线程数，必须大于等于1
     * @param topic          要消费的topic
     * @param messageHandler 消息的处理逻辑
     */
    void consume(int threadNum, String topic, MessageHandler messageHandler);

}
